10af128e9654d346a3f6ca6a2d3201e9b409e2a1,spring-messaging/src/main/java/org/springframework/messaging/simp/config/AbstractMessageBrokerConfiguration.java,AbstractMessageBrokerConfiguration,clientOutboundChannel,#,130
Before Change
public AbstractSubscribableChannel clientOutboundChannel() {
ExecutorSubscribableChannel channel = new ExecutorSubscribableChannel(clientOutboundChannelExecutor());
ChannelRegistration r = getClientOutboundChannelRegistration();
if (r.hasInterceptors()) {
channel.setInterceptors(r.getInterceptors());
}
return channel;
}
After Change
public AbstractSubscribableChannel clientOutboundChannel() {
ExecutorSubscribableChannel channel = new ExecutorSubscribableChannel(clientOutboundChannelExecutor());
ChannelRegistration reg = getClientOutboundChannelRegistration();
channel.setInterceptors(reg.getInterceptors());
return channel;
}